/*******************************************************************************
 * The MOSES project, model based software engineering of networked embedded systems.
 * 
 * Copyright (C) 2010-2013, University of Applied Sciences Wildau,
 * Telematics Research Group, http://www.tm.th-wildau.de/research-group
 * 
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as
 * published by the Free Software Foundation; either version 3 of the
 * License, or (at your option) any later version.
 * 
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, see <http://www.gnu.org/licenses>.
 * 
 * Contributors:
 *     University of Applied Sciences Wildau - initial API and implementation
 * 
 * If you are interested in a commercial license please contact us via 
 * e-mail: ralf.vandenhouten@th-wildau.de.
 ******************************************************************************/
package de.thwildau.tm.moses.examples.nmea.app;

import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelPipelineFactory;
import org.jboss.netty.channel.Channels;
import org.jboss.netty.channel.SimpleChannelHandler;
import org.jboss.netty.handler.codec.frame.LineBasedFrameDecoder;

import de.thwildau.tm.moses.examples.nmea.data.Nmea;

/**
 * A pipeline factory that creates a pipeline to decode NMEA messages. The created pipeline consist of the
 * following {@link ChangeHandler}.
 * <ul>
 * <li>A {@link LineBasedFrameDecoder}</li>
 * <li>The {@link NmeaDecoder}</li>
 * <li>A {@link SimpleChannelHandler} that forwards the {@link Nmea} message to a {@link NmeaMessageListener}</li>
 * <ul>
 * 
 * @author Thomas Kistel
 * @version $Revision: 764 $
 */
public class NmeaPipelineFactory implements ChannelPipelineFactory {

    private NmeaMessageListener messageListener;


    public NmeaPipelineFactory(NmeaMessageListener messageListener) {
        this.messageListener = messageListener;
    }

    @Override
    public ChannelPipeline getPipeline() throws Exception {
        final ChannelPipeline pipeline = Channels.pipeline();
        pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(100));
        pipeline.addLast("nmeaDecoder", new NmeaDecoder());
        pipeline.addLast("appHandler", new NmeaMessageHandler(messageListener));
        return pipeline;
    }
}
